// let mysql = require('mysql');

// //创建一个数据库的链接对象
// let aa = mysql.createConnection({
//     host: 'localhost',
//     user: 'root',
//     password:'Hyf182812#',
//     database:'niubi',
// })

// aa.connect((err)=>{
//     if(err){
//         console.log(err)
//     }else{
//         console.log('链接成功')
//     }
// })

// let bb="select * from user";


// aa.query(bb,(err,res)=>{
//     if(!err){
//         console.log(res)
//     }
// })
let mysql = require('mysql');

let pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'Hyf182812#',
    database: 'blogdata',
    maxContentLength: 10,
})

let query = function(sql) { 
return new Promise((resolve,reject)=>{
    pool.getConnection(function (err, connection) {
        // console.log(pool.getConnection)
        // console.log(err)
        connection.query(sql, (err, res) => {
            if(!err){
                resolve(res)         
            }else{
                reject("err"+err)  
            }  
        })
        // 释放连接（没有删除，实际上是返回到数据库连接池了）
        connection.release()
    })
})
    
}


// exports.query = query;
module.exports = query;
